package com.ccc.mq.dynamic.pojo;

import com.baomidou.mybatisplus.annotation.TableField;
import lombok.Data;

import java.io.Serializable;

/**
 * @author superC
 * @version 1.0.0
 * @date 2023/3/25
 */

@Data
public class RocketTopicMsgVO implements Serializable {

    private static final long serialVersionUID = -5569747880844038586L;
    /**
     * rocketmq的ip地址，必填项
     */
    private String addrIp;

    /**
     * 表rocket_topic_msg_model主键ID
     */
    private Long rocketTopicId;

    /**
     * 消费者组，必填项
     */
    private String consumerGroup;

    /**
     * 主题名，必填项
     */
    private String topicName;

    /**
     * tag,多个tag时，用|隔开；非必填
     */
    private String subExpression;

    /**
     * 1集群模式，2广播模式，必填项
     */
    private Integer msgModelType;

    /**
     * 是否为顺序消费， 1 true; 0 false;
     */
    private Boolean orderly;

}